/**
 *  src.module.DB.mongdb.js
 */

var fs = require('fs');
var path = require('path');
var mongoose = require('mongoose');
var logger = require('pomelo-logger').getLogger('mongodb-log');
var conf = require('../../../config/index').db;


var dbURL = "mongodb://" + conf.mongodb.db_user + ":" + conf.mongodb.db_pwd + "@" + conf.mongodb.db_host + ":" + conf.mongodb.db_port + "/" + conf.mongodb.db_name;

// mongoose.Promise = global.Promise
var options = {
    auto_reconnect:conf.server.auto_reconnect,
    poolSize:conf.server.poolSize
};
mongoose.connect(dbURL, options);

mongoose.connection.on('connected', function (err) {
    if (err){
        logger.error('Database connection failure');
    } else {
        logger.info('Mongo Database connection Success!');
        logger.info('connection address:'+dbURL);
    }
});

mongoose.connection.on('error', function (err) {
    logger.error('Mongoose connected error ' + err);
});

mongoose.connection.on('disconnected', function () {
    logger.error('Mongoose disconnected');
});

process.on('SIGINT', function () {
    mongoose.connection.close(function () {
        logger.info('Mongoose disconnected through app termination');
        process.exit(0);
    });
});

var DB = function () {
    this.mongoClient = {};
    var filename = path.join(path.dirname(__dirname).replace('app', ''), '../../config/bin/table.json');
    this.tabConf = JSON.parse(fs.readFileSync(path.normalize(filename)));
};

/**
 * 初始化mongoose model
 * @param table_name 表名称(集合名称)
 */
DB.prototype.getConnection = function (table_name) {
    if (!table_name) return;
    if (!this.tabConf[table_name]) {
        logger.error('No table structure');
        return false;
    }

    var client = this.mongoClient[table_name];
    if (!client) {
        //构建用户信息表结构
        var nodeSchema = new mongoose.Schema(this.tabConf[table_name]);

        //构建model
        client = mongoose.model(table_name, nodeSchema, table_name);

        this.mongoClient[table_name] = client;
    }
    return client;
};

/**
 * 保存数据
 * @param table_name 表名
 * @param fields 表数据
 * @param callback 回调方法
 */
DB.prototype.save = function (table_name, fields, callback) {
    if (!fields) {
        if (callback) callback({msg: 'Field is not allowed for null'});
        return false;
    }

    var err_num = 0;
    for (var i in fields) {
        if (!this.tabConf[table_name][i]) err_num ++;
    }
    if (err_num > 0) {
        if (callback) callback({msg: 'Wrong field name'});
        return false;
    }

    var node_model = this.getConnection(table_name);
    var mongooseEntity = new node_model(fields);
    mongooseEntity.save(function (err, res) {
        if (err) {
            if (callback) callback(err);
        } else {
            if (callback) callback(null, res);
        }
    });
};

/**
 * 更新数据
 * @param table_name 表名
 * @param conditions 更新需要的条件 {_id: id, user_name: name}
 * @param update_fields 要更新的字段 {age: 21, sex: 1}
 * @param callback 回调方法
 */
DB.prototype.update = function (table_name, conditions, update_fields, callback) {
    if (!update_fields || !conditions) {
        if (callback) callback({msg: 'Parameter error'});
        return;
    }
    var node_model = this.getConnection(table_name);
    node_model.update(conditions, {$set: update_fields}, {multi: true, upsert: true}, function (err, res) {
        if (err) {
            if (callback) callback(err);
        } else {
            if (callback) callback(null, res);
        }
    });
};

/**
 * 更新数据方法(带操作符的)
 * @param table_name 数据表名
 * @param conditions 更新条件 {_id: id, user_name: name}
 * @param update_fields 更新的操作符 {$set: {id: 123}}
 * @param callback 回调方法
 */
DB.prototype.updateData = function (table_name, conditions, update_fields, callback) {
    if (!update_fields || !conditions) {
        if (callback) callback({msg: 'Parameter error'});
        return;
    }
    var node_model = this.getConnection(table_name);
    node_model.findOneAndUpdate(conditions, update_fields, {multi: true, upsert: true}, function (err, data) {
        if (callback) callback(err, data);
    });
};

/**
 * 删除数据
 * @param table_name 表名
 * @param conditions 删除需要的条件 {_id: id}
 * @param callback 回调方法
 */
DB.prototype.remove = function (table_name, conditions, callback) {
    var node_model = this.getConnection(table_name);
    node_model.remove(conditions, function (err, res) {
        if (err) {
            if (callback) callback(err);
        } else {
            if (callback) callback(null, res);
        }
    });
};

/**
 * 查询数据
 * @param table_name 表名
 * @param conditions 查询条件
 * @param fields 待返回字段
 * @param callback 回调方法
 */
DB.prototype.find = function (table_name, conditions, fields, callback) {
    var node_model = this.getConnection(table_name);
    node_model.find(conditions, fields || null, {}, function (err, res) {
        if (err) {
            callback(err);
        } else {
            callback(null, res);
        }
    });
};

/**
 * 查询单条数据
 * @param table_name 表名
 * @param conditions 查询条件
 * @param callback 回调方法
 */
DB.prototype.findOne = function (table_name, conditions, callback) {
    var node_model = this.getConnection(table_name);
    node_model.findOne(conditions, function (err, res) {
        if (err) {
            callback(err);
        } else {
            callback(null, res);
        }
    });
};

/**
 * 根据_id查询指定的数据
 * @param table_name 表名
 * @param _id 可以是字符串或 ObjectId 对象。
 * @param callback 回调方法
 */
DB.prototype.findById = function (table_name, _id, callback) {
    var node_model = this.getConnection(table_name);
    node_model.findById(_id, function (err, res){
        if (err) {
            callback(err);
        } else {
            if(res && res.length > 0)res = res.toJSON();
            callback(null, res);
        }
    });
};

/**
 * 返回符合条件的文档数
 * @param table_name 表名
 * @param conditions 查询条件
 * @param callback 回调方法
 */
DB.prototype.count = function (table_name, conditions, callback) {
    var node_model = this.getConnection(table_name);
    node_model.count(conditions, function (err, res) {
        if (err) {
            callback(err);
        } else {
            callback(null, res);
        }
    });
};

/**
 * 查询符合条件的文档并返回根据键分组的结果
 * @param table_name 表名
 * @param field 待返回的键值
 * @param conditions 查询条件
 * @param callback 回调方法
 */
DB.prototype.distinct = function (table_name, field, conditions, callback) {
    var node_model = this.getConnection(table_name);
    node_model.distinct(field, conditions, function (err, res) {
        if (err) {
            callback(err);
        } else {
            callback(null, res);
        }
    });
};

/**
 * 连写查询
 * @param table_name 表名
 * @param conditions 查询条件 {a:1, b:2}
 * @param options 选项：{fields: "a b c", sort: {time: -1}, limit: 10}
 * @param callback 回调方法
 */
DB.prototype.where = function (table_name, conditions, options, callback) {
    var node_model = this.getConnection(table_name);
    node_model.find(conditions)
        .select(options.fields || '')
        .sort(options.sort || {})
        .limit(options.limit || {})
        .exec(function (err, res) {
            if (err) {
                callback(err);
            } else {
                callback(null, res);
            }
        });
};

module.exports = new DB();


// var db = require("./mongodb");
// 保存
// var data = { "activity_id" : 2, "parent_id" : 0, "activity_name" : "双十二", "activity_title" : "双十二", "activity_keyword" : "双十二", "activity_desc" : "双十二", "activity_template" : "双十二", "activity_content" : "", "activity_page_url" : "/shuangshier.html", "activity_display" : 1, "activity_order" : 1, "activity_type" : 1, "description" : "1", "activity_status" : 1, "activity_ctime" : "Wed Mar 08 2017 18:10:16 GMT+0800 (CST)", "activity_cuser" : "1" };
// db.save("activity_page", data, function(err, result){
//     if(err){
//         console.log(err);
//     }else{
//         console.log(result);
//     }
// });
// 修改
// * @param conditions 更新需要的条件 {_id: id, user_name: name}
// * @param update_fields 要更新的字段 {age: 21, sex: 1}
// var id = "58ea1b3dc3bed2a995cad820";
// var aconditions={_id:id};
// var update_fields = {activity_template:"我是模板",activity_ctime:Date.now};
// db.update("activity_page", aconditions, update_fields, function(err, result){
//     if(err) console.log(err);
//     else console.log(result.toString());
// });
// 查询
// db.find("mobileh5",{},{},function (err, result) {
//     if(err) console.log(err);
//     else console.log("result:"+result.toString());
// });
//
// db.findById('mobileh5','58f0368fb250df7269bdb712',function(err, result){
//     if(err) console.log(err);
//     else console.log("result:"+result.toString());
// });
// * 连写查询
// * @param table_name 表名
// * @param conditions 查询条件 {a:1, b:2}
// * @param options 选项：{fields: "a b c", sort: {time: -1}, limit: 10}
// * @param callback 回调方法
// var activity_name = "双十";
// var pattern = new RegExp("^.*"+activity_name+".*$"); //用正则表达式模糊查询
// db.where("activity_page",{activity_name:pattern},{limit:10},function (err, result) {
//     if(err) console.log(err);
//     else console.log(result.toString());
// });

// mongoose 链接
// var mongoose = require('mongoose');
// var db       = mongoose.connect('mongodb://127.0.0.1:27017/nodeweb');
// // 链接错误
// db.connection.on('error', function(error) {
//     console.log(error);
// });
//
// db.connection.on("open", function () {
//     console.log("——数据库连接成功！——");
// });
//
// // Schema 结构
// var vipSchema = new mongoose.Schema({
//     name : {type : String, default : 'java'},
//     addr    : {type : String},
//     addTime  : {type : Date, default: Date.now},
//     age      : {type : Number}
// });
// //中间件
// //save之前触发
// vipSchema.pre('save', function(next){
//     console.log("pre save");
//     next();
// });
// vipSchema.post('save', function (doc) {
//     //doc是当前插入的文档
//     console.log(doc);
// });
//
// // model
// var vipModel = db.model('vip', vipSchema);
// // 增加记录 基于 entity 操作
// var doc = {name : 'java', age:20, addr:"shanghai"};
// var vipEntity= new vipModel(doc);
//
// vipEntity.save(function(error) {
//     if(error) {
//         console.log(error);
//     } else {
//         console.log('saved OK!');
//     }
//     // 关闭数据库链接
//     db.disconnect();
// });
// //增加记录 基于model操作
// vipModel.create(doc, function(error){
//     if(error) {
//         console.log(error);
//     } else {
//         console.log('save ok');
//     }
//     // 关闭数据库链接
//     db.disconnect();
// });

// 第一版
// var conf = require('../../conf/index');
// var mongodb = require('mongodb');
// var server = new mongodb.Server(conf.mongdb.db_host,conf.mongdb.db_port,{auto_reconnect:true});
// var db = new mongodb.Db('nodeweb',server,{safe:true});
//
//     db.open(function(err,db){
//         if(!err) {
//             console.log('connect');
//             db.collection('nodeweb',{safe:true},function(err,collection){
//                 if(err){
//                     console.log(err);
//                 }else{
//                     var tmp1 = {title:'hello'};
//                     var tmp2 = {title:'world'};
//                     // collection.insert([tmp1,tmp2],{safe:true},function(err,result){
//                     //     console.log(result);
//                     //     // callback(err, result);
//                     // });
//                     collection.find().toArray(function(err,docs){
//                         console.log('find');
//                         console.log(docs);
//                     });
//                     // collection.findOne(function(err,doc){
//                     //     // console.log('findOne');
//                     //     // console.log(doc);
//                     // });
//                     console.log('open collection');
//                 }
//             });
//             // 删除
//             // db.dropCollection('nodeweb',{safe:true},function(err,result){
//             //     console.log(result);
//             // });
//         }else {
//             console.log('e:'+err);
//         }
//     });

